package com.wjy.common.mq.ps;

import com.wjy.common.util.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class Subscriber {

    @Autowired
    private RedisUtil redisUtil;

    public void subscrib(JedisPubSubListener listener, String... messages) {
        redisUtil.subscribe(listener, messages);
    }

}
